#include "app_mqtt.h"

 
/// @brief 接收回调
/// @param  
/// @param  
void mqtt_recv_cb(void *data,int dataLen)
{
    log_info("MQTT回调函数接收 message:%.*s",dataLen,data);
}

int main(int argc,char const *argv[])
{
    //初始化mqtt
    app_mqtt_init();


    //注册接收回调
    app_mqtt_recv_callback_register(mqtt_recv_cb);

    //发送消息
    app_mqtt_send("你好世界",strlen("你好世界"));
    
    //关闭连接
    app_mqtt_deinit();
    while (1)
    {
        
    }
    return 0;
}